package greate.project.mysql;

import org.apache.camel.builder.RouteBuilder;

/**
 * @author v_zhangshun01
 */
public class ProviderRouter extends RouteBuilder {

    private String to;

    public ProviderRouter(String name) {
        this.to = name;
    }



    @Override
    public void configure() throws Exception {

        from("timer://queryAward?period=60s")
                .process(exchange -> {
                    System.out.println("88888");
                    exchange.getMessage().setBody("****************");
                })
                .to("direct:" + to);
    }

}
